(pynumaflow-lite) ➜  sourcetransform git:(source-transformer) ✗ curl -kq -X POST -d "hello world" https://localhost:8443/vertices/in
Handling connection for 8443
{"message":"Data received successfully","id":"019ae76a-2cf5-7542-a42e-58e7e8686b28"}
(pynumaflow-lite) ➜  sourcetransform git:(source-transformer) ✗  curl -kq -X POST -d "hello world" https://localhost:8443/vertices/in
Handling connection for 8443
{"message":"Data received successfully","id":"1"}
(pynumaflow-lite) ➜  sourcetransform git:(source-transformer) ✗ curl -kq -X POST -H "x-numaflow-id: 1" -H "x-numaflow-event-time: 63006726000" -d "hello world" https://localhost:8443/vertices/in
Handling connection for 8443
{"message":"Data received successfully","id":"1"}

(pynumaflow-lite) ➜  sourcetransform git:(source-transformer) ✗ kl sourcetransform-event-filter-in-0-jo1x3 -c transformer
Registering signal handlers <_UnixSelectorEventLoop running=True closed=False debug=True>
Starting NumaflowCore: event_loop=Py(0xffffb27b9710)
Got event time: 2025-12-04 03:31:26.581799+00:00, it is after year 2022, so forwarding to after_year_2022
Messages { messages: [Message { keys: Some([]), value: [104, 101, 108, 108, 111, 32, 119, 111, 114, 108, 100], event_time: 2023-01-01T00:00:00Z, tags: Some(["after_year_2022"]) }] }
Got event time: 2022-09-12 18:18:46+00:00, it is within year 2022, so forwarding to within_year_2022
Messages { messages: [Message { keys: Some([]), value: [104, 101, 108, 108, 111, 32, 119, 111, 114, 108, 100, 38, 104, 101, 108, 108, 111, 32, 119, 111, 114, 108, 100], event_time: 2022-01-01T00:00:00Z, tags: Some(["within_year_2022"]) }] }
Got event time: 1971-12-31 05:52:06+00:00, it is before 2022, so dropping
Messages { messages: [Message { keys: None, value: [], event_time: 1971-12-31T05:52:06Z, tags: Some(["U+005C__DROP__"]) }] }